package com.msblearn.C_013;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * Queue接口中主要的方法
 */
public class T003_ConcurrentQueue {
    public static void main(String[] args) {
        Queue<String> strings = new ConcurrentLinkedQueue<>();
        //offer：添加。返回值boolean
        //add添加失败抛异常
        for(int i=0;i<10;i++){
            strings.offer("aa"+i);//相当于add
        }

        System.out.println(strings);

        System.out.println(strings.size());
        //获取第一个并从队列中移除掉。poll失败返回null,remove失败抛出异常。
        System.out.println(strings.poll());
        System.out.println(strings.size());
        //获取第一个值不移除
        System.out.println(strings.peek());
        System.out.println(strings.size());
    }
}
